package com.just.springbootmessage.activemq.m2;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;
import javax.jms.Destination;
import java.io.Serializable;

/**
 * 点对点的方式
 * 生产者发送的消息只要消费者有一个收到就结束
 */
@Service("m2producer")
public class M2Producer {
    //也可以注入jmsTemplate，JmsMessagingTemplate对jmsTemplate进行了封装
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    //发送消息，destination是发送到的队列，message是待发送的消息
    public void sendMessage(Destination destination,String message){
        jmsMessagingTemplate.convertAndSend(destination,message);
    }
    //发送的消息为一个对象
    public void sendObjectMessage(Destination destination,final Serializable message){
        jmsMessagingTemplate.convertAndSend(destination,message);
    }
}
